//package com.maple.kafka;
//
//import org.springframework.kafka.annotation.KafkaListener;
//import org.springframework.stereotype.Component;
//
///**
// * 描述: com.maple.kafka
// *
// * @author hz.lei
// * @date 2018年04月28日 上午12:40
// */
//@Component
//public class ReceiveMsg {
//
//
//    @KafkaListener(topics = "test")
//    public void processMessage(String content) {
//        System.out.println("console output receive message: --> " + content);
//    }
//}
